package com.gientech.springstream.ingration;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * 消费者示例
 */
public interface Sink {

    String INPUT = "test-exchange";
    /**
     * 订阅的消息
     * @return
     */
    @Input(INPUT)
    SubscribableChannel  input();

}
